package com.bindatax.core.database.operate;

import com.bindatax.core.task.DataTask;
import org.pentaho.di.core.row.ValueMetaInterface;

import java.sql.ResultSet;

public interface DatabaseOperateInterface {
    String getDatabaseType();
    boolean checkTransValue(ValueMetaInterface commValueMeta);//检查是否需要转换值
    Object transValue(ResultSet sourceResultSet,ValueMetaInterface commValueMeta) throws Exception;//单独转换值
    String getLimitSql(String tableName);
    boolean checkDatabaseType(String databaseProductName,String databaseProductVersion);//校验类型
    String[] getPrimaryKeys(DataTask thisDataTask);//获取目标表主键或表唯一字段列或联合主键字段
    String getWriteSql(DataTask thisDataTask);
}
